982501a5ed2c5b0eb55a24a87e98bd871c59068a,src/test/java/net/jodah/failsafe/ListenerConfigTest.java,ListenerConfigTest,bindListeners,#SyncFailsafe#,114
Before Change
failsafe.onAbort(e -> abort.incrementAndGet());
failsafe.onAbort((r, e) -> abortResult.incrementAndGet());
failsafe.onAbort((r, e, c) -> ctxAbort.incrementAndGet());
failsafe.onAbortAsync(e -> {
asyncAbort.incrementAndGet();
waiter.resume();
} , executor);
failsafe.onAbortAsync((r, e) -> {
asyncAbortResult.incrementAndGet();
waiter.resume();
} , executor);
failsafe.onAbortAsync((r, e, c) -> {
asyncCtxAbort.incrementAndGet();
waiter.resume();
} , executor);
failsafe.onFailure(e -> failure.incrementAndGet());
failsafe.onFailure((r, f) -> failureResult.incrementAndGet());
failsafe.onFailure((r, f, s) -> ctxFailure.incrementAndGet());
failsafe.onFailureAsync(e -> asyncFailure.incrementAndGet(), executor);
failsafe.onFailureAsync((r, f) -> asyncFailureResult.incrementAndGet(), executor);
failsafe.onFailureAsync((r, f, s) -> asyncCtxFailure.incrementAndGet(), executor);
After Change
<T> SyncFailsafe<T> registerListeners(SyncFailsafe<T> failsafe) {
failsafe.onAbort(e -> abort.sync(1));
failsafe.onAbort((r, e) -> abort.sync(2));
failsafe.onAbort((r, e, c) -> abort.sync(3));
failsafe.onAbortAsync(e -> abort.async(4), executor);
failsafe.onAbortAsync((r, e) -> abort.async(5), executor);
failsafe.onAbortAsync((r, e, c) -> abort.async(6), executor);
abort.asyncListeners = 3;
failsafe.onComplete((r, f) -> complete.sync(1));
failsafe.onComplete((r, f, s) -> complete.sync(2));
failsafe.onCompleteAsync((r, f) -> complete.async(3), executor);
failsafe.onCompleteAsync((r, f, c) -> complete.async(4), executor);
complete.asyncListeners = 2;
failsafe.onFailedAttempt(e -> failedAttempt.sync(1));
failsafe.onFailedAttempt((r, f) -> failedAttempt.sync(2));
failsafe.onFailedAttempt((r, f, c) -> failedAttempt.sync(3, c));
failsafe.onFailedAttemptAsync(e -> failedAttempt.async(4), executor);
failsafe.onFailedAttemptAsync((r, f) -> failedAttempt.async(5), executor);
failsafe.onFailedAttemptAsync((r, f, c) -> failedAttempt.async(6, c), executor);
failedAttempt.asyncListeners = 3;
failsafe.onFailure(e -> failure.sync(1));
failsafe.onFailure((r, f) -> failure.sync(2));
failsafe.onFailure((r, f, s) -> failure.sync(3));
failsafe.onFailureAsync(e -> failure.async(4), executor);
failsafe.onFailureAsync((r, f) -> failure.async(5), executor);
failsafe.onFailureAsync((r, f, s) -> failure.async(6), executor);
failure.asyncListeners = 3;